<?php
/**
 * 直播
 * User: myl
 * Date: 2018/9/7
 * Time: 10:29
 */
namespace app\api\controller;

use think\Db;
use think\Session;
use think\Verify;
use think\Cookie;

class Live extends Base
{
    /**
     * 回调-添加直播记录（房间）
     */
    public function createsTream()
    {
        $map['stream_sid'] = $_POST['stream_sid'];// 流server ID（zego后台生成, 流唯一标识）
        $map['channel_id'] = $_POST['channel_id'];// 客户端RoomID（频道ID）
        $map['title'] = $_POST['title'];// 直播标题
        $map['stream_alias'] = $_POST['stream_alias'];// 客户端StreamID（流名）
        $map['user_id'] = $_POST['publish_id'];// 客户端-用户ID
        $map['user_name'] = $_POST['publish_name'];// 客户端-用户名
        $map['pic_url'] = implode(",", $_POST['pic_url']);;// 截图地址
        $map['k_timestamp'] = $_POST['timestamp'];// 服务器当前时间 Uinx时间戳 （上播时间）
        $map['status'] = 1;// 直播状态  1.在播  2.下播

        $rs = M("live")->insert($map);// 添加直播记录
        if ($rs) {
            $this->ajaxReturn(['status' => 1, 'msg' => 'Success！']);
        } else {
            $this->ajaxReturn(['status' => -1, 'msg' => 'Errer！']);
        }
    }

    /**
     * 回调-修改直播状态（房间）
     */
    public function deletesTream()
    {
        $map['stream_sid'] = $_POST['stream_sid'];// 流server ID（zego后台生成, 流唯一标识）
        $map['channel_id'] = $_POST['channel_id'];// 客户端RoomID（频道ID）
        $map['stream_alias'] = $_POST['stream_alias'];// 客户端StreamID（流名）
        $map['type'] = $_POST['type'];// 流server ID（zego后台生成, 流唯一标识）
        $map['j_timestamp'] = $_POST['timestamp'];// 服务器当前时间 Uinx时间戳 （下播时间）
        $map['status'] = 2;// 直播状态  1.在播  2.下播

        $rs = M("live")->where("channel_id",$map['channel_id'])->find();
        if ($rs) {
            M("live")->where("channel_id",$map['channel_id'])->update($map);
        } else {
            $this->ajaxReturn(['status' => -1, 'msg' => 'Errer！']);
        }
    }

    /**
     * 获取直播列表直播
     */
    public function liveList()
    {
        $rs = M("live")->where("status=1")->select(); // 在播的直播列表 直播状态（status）  1.在播  2.下播
        if ($rs) {
            foreach ($rs as $key => $val) {
                $img = M("users")->field('head_pic')->where("user_id",$val['user_id'])->find();
                $rs[$key]['img']  = $img['head_pic'];
            }
            $this->ajaxReturn(['status' => 1, 'msg' => 'Success！', 'result' => $rs]);
        } else {
            $this->ajaxReturn(['status' => -1, 'msg' => 'Errer！','result' => []]);
        }
    }
}